//package com.example.config;
//
//
//import org.springframework.stereotype.Component;
//import org.springframework.web.bind.annotation.PathVariable;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnMessage;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.PathParam;
//import javax.websocket.server.ServerEndpoint;
//import java.io.IOException;
//
//@Component
//@ServerEndpoint("/websocket")
//public class WebSocketEndpoint {
//
//    private Session session;
//
////    连接成功的时候调用的函数  传递一个用户的id
//    @OnOpen
//    public void onOpen(Session session , @PathParam("userId") String userId){
////        用户存放到连接池中
//        System.out.println(2);
//        SessionPool.sessions.put(userId,session);
//    }
//
//
////    关闭的时候调用
//    @OnClose
//    public void onClose(Session session) throws IOException {
////        把会话删除
//        SessionPool.close(session.getId());
//        session.close();
//    }
//
////    接收到消息
//    @OnMessage
//    public void onMessage(String message,Session session){
////        消息转发
////        消息群发
//        SessionPool.sendMessage(message);
//    }
//}
